3f6b909c3d4eddd1dc282ac065e90233809873f5,components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumer.java,KubernetesPodsConsumer,doStart,#,52
Before Change
super.doStart();
map = new ConcurrentHashMap<Long, PodEvent>();
if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getOauthToken())) {
if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getNamespaceName())) {
getEndpoint().getKubernetesClient().pods()
.inNamespace(getEndpoint().getKubernetesConfiguration().getNamespaceName())
.watch(new Watcher<Pod>() {
@Override
public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action,
Pod resource) {
PodEvent pe = new PodEvent(action, resource);
map.put(System.currentTimeMillis(), pe);
}
@Override
public void onClose(KubernetesClientException cause) {
if (cause != null) {
LOG.error(cause.getMessage(), cause);
}
}
});
} else {
getEndpoint().getKubernetesClient().pods().watch(new Watcher<Pod>() {
@Override
public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, Pod resource) {
PodEvent pe = new PodEvent(action, resource);
map.put(System.currentTimeMillis(), pe);
}
@Override
public void onClose(KubernetesClientException cause) {
if (cause != null) {
LOG.error(cause.getMessage(), cause);
}
}
});
}
}
}
After Change
@Override
protected void doStart() throws Exception {
super.doStart();
executor = getEndpoint().createExecutor();
executor.submit(new PodsConsumerTask());
}
@Override